package com.stan.core.spark;

import com.alibaba.fastjson.JSONObject;
import com.stan.core.vo.Task;
import org.apache.spark.SparkConf;
import org.apache.spark.api.java.JavaSparkContext;

/**
 * Spark计算接口
 */
public interface SparkCalculator {
    /**
     * 开始运行
     */
    void run(String[] args);

    /**
     * 执行计算
     */
    void compute(JavaSparkContext javaSparkContext, Task task);

}
